//package com.zrx.zrxaiagent.rabbitMQ;
//
//import org.springframework.amqp.rabbit.core.RabbitTemplate;
//import org.springframework.beans.factory.annotation.Autowired;
//import org.springframework.stereotype.Service;
//
//@Service
//public class DelayTaskService {
//
//    @Autowired
//    private RabbitTemplate rabbitTemplate;
//
//    /**
//     * 发送延迟任务
//     * @param task 延迟任务
//     * @param delaySeconds 延迟秒数
//     */
//    public void sendDelayTask(DelayTask task, long delaySeconds) {
//        sendDelayTask("delay.exchange", "delay.routingkey", task, delaySeconds);
//    }
//
//    /**
//     * 发送延迟任务
//     * @param exchange 交换机
//     * @param routingKey 路由键
//     * @param task 延迟任务
//     * @param delaySeconds 延迟秒数
//     */
//    public void sendDelayTask(String exchange, String routingKey, DelayTask task, long delaySeconds) {
//        rabbitTemplate.convertAndSend(exchange, routingKey, task, message -> {
//            message.getMessageProperties().getHeaders().put("x-delay", delaySeconds * 1000);
//            return message;
//        });
//    }
//
//    /**
//     * 发送普通任务（立即执行）
//     */
//    public void sendImmediateTask(DelayTask task) {
//        rabbitTemplate.convertAndSend("immediate.exchange", "immediate.routingkey", task);
//    }
//}
